package com.lry.basic.redis;

import redis.clients.jedis.Jedis;

public class RedisConsumer {

    //队列lpush+rpop ，栈，阻塞队列lpush+brpop，阻塞栈
    public static void recv(Jedis jedis ,String topic){
        while(true){
            System.out.println(jedis.brpop(1000, topic));
        }
    }

}
